/**
* Project Name:myservice
* Date:2018年12月16日
* Copyright (c) 2018, jingma All Rights Reserved.
*/

package cn.benma666.kettle.ljq;

import cn.benma666.iframe.MyParams;
import cn.benma666.iframe.Result;
import cn.benma666.kettle.domain.KettleKzZycs;
import cn.benma666.sjzt.Db;
import com.alibaba.fastjson.JSONObject;
import org.beetl.sql.core.SqlId;

/**
 * 参数设置拦截器 <br/>
 * date: 2018年12月16日 <br/>
 * @author jingma
 * @version 0.1
 */
public class JobCsszLjq extends KettleLjq {

    @Override
    public Result plbc(MyParams myParams) {
        myParams.set($_SYS_BATCH,false);
        Result r = super.plbc(myParams);
        if(r.isStatus()){
            return success("参数保存成功");
        }else {
            return r;
        }
    }

    @Override
    public Result save(MyParams myParams) {
        KettleKzZycs yobj = myParams.yobj(KettleKzZycs.class);
        JSONObject obj = getDb().findFirst(SqlId.of("kee","selectZycs"), Db.buildMap(yobj.getId()));
        if(obj.getBooleanValue("yxx")){
            //更新
            getDb().update(SqlId.of("kee","updateZycs"),
                    Db.buildMap(yobj.getValue(), obj.getIntValue("id_job"),obj.getString("key")));
        }else{
            //新增
            getDb().update(SqlId.of("kee","insertZycs"),
                    Db.buildMap(obj.getIntValue("id_job"),obj.getString("key"),yobj.getValue()));
        }
        return success("保存成功");
    }

}
